package com.kafka.config;

import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.annotation.KafkaListener;

/**
 * @author God.Jhon.Black
 * @date 2023-02-06
 */
@Configuration
public class KafkaConfig {

    @KafkaListener(topics = {"t-cityos-dright-user-role-change"},groupId = "t-cityos-dright")
    public void taskStateConsumer(String msg) {
        System.out.println(msg);
    }
}
